package com.paradogs.framework.server;

import com.paradogs.framework.core.msg.ByteData;
import com.paradogs.framework.core.netty.server.PRAbServerMsgHandler;
import com.paradogs.framework.core.queue.PRQueueHolder;
import io.netty.channel.ChannelHandler;
import org.springframework.stereotype.Component;

/**
 * @author: yumi
 * @date: 2023/11/29  10:41
 * @Description: TODO
 */
@Component
@ChannelHandler.Sharable
public class ServerMsgHandler extends PRAbServerMsgHandler<ByteData> {

    @Override
    protected void processMsg(ByteData msg) throws Exception {
        PRQueueHolder.putMsg(PRQueueHolder.QueueType.MAIN, msg);
    }
}
